🎖️GitЯра🎖️ - /page/blob.mu

T8b949e/*

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.feature.firmware.ota

Tff7b72import T7ee787co.touchlab.kermit.Logger

Tff7b72import T7ee787kotlinx.coroutines.CompletableDeferred

Tff7b72import T7ee787kotlinx.coroutines.CoroutineDispatcher

Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope

Tff7b72import T7ee787kotlinx.coroutines.CoroutineStart

Tff7b72import T7ee787kotlinx.coroutines.Job

Tff7b72import T7ee787kotlinx.coroutines.SupervisorJob

Tff7b72import T7ee787kotlinx.coroutines.TimeoutCancellationException

Tff7b72import T7ee787kotlinx.coroutines.cancel

Tff7b72import T7ee787kotlinx.coroutines.channels.Channel

Tff7b72import T7ee787kotlinx.coroutines.currentCoroutineContext

Tff7b72import T7ee787kotlinx.coroutines.delay

Tff7b72import T7ee787kotlinx.coroutines.ensureActive

Tff7b72import T7ee787kotlinx.coroutines.flow.catch

Tff7b72import T7ee787kotlinx.coroutines.flow.collect

Tff7b72import T7ee787kotlinx.coroutines.flow.launchIn

Tff7b72import T7ee787kotlinx.coroutines.flow.onEach

Tff7b72import T7ee787kotlinx.coroutines.launch

Tff7b72import T7ee787kotlinx.coroutines.withTimeoutOrNull

Tff7b72import T7ee787org.meshtastic.core.ble.BleCharacteristic

Tff7b72import T7ee787org.meshtastic.core.ble.BleConnectionFactory

Tff7b72import T7ee787org.meshtastic.core.ble.BleConnectionState

Tff7b72import T7ee787org.meshtastic.core.ble.BleDevice

Tff7b72import T7ee787org.meshtastic.core.ble.BleScanner

Tff7b72import T7ee787org.meshtastic.core.ble.BleService

Tff7b72import T7ee787org.meshtastic.core.ble.BleWriteType

Tff7b72import T7ee787org.meshtastic.core.ble.MeshtasticBleConstants.OTA_NOTIFY_CHARACTERISTIC

Tff7b72import T7ee787org.meshtastic.core.ble.MeshtasticBleConstants.OTA_SERVICE_UUID

Tff7b72import T7ee787org.meshtastic.core.ble.MeshtasticBleConstants.OTA_WRITE_CHARACTERISTIC

Tff7b72import T7ee787org.meshtastic.core.common.util.safeCatching

Tff7b72import T7ee787kotlin.concurrent.Volatile

Tff7b72import T7ee787kotlin.time.Duration

Tff7b72import T7ee787kotlin.time.Duration.Companion.milliseconds

Tff7b72import T7ee787kotlin.time.Duration.Companion.seconds

T8b949e/** BLE transport implementation for ESP32 Unified OTA protocol using Kable. */

Tff7b72class T56d364BleOtaTransportTb4b4b4(

Tff7b72private Tff7b72val Te6edf3scannerTb4b4b4: Te6edf3BleScannerTb4b4b4,

Te6edf3connectionFactoryTb4b4b4: Te6edf3BleConnectionFactoryTb4b4b4,

Tff7b72private Tff7b72val Te6edf3addressTb4b4b4: Tffa657StringTb4b4b4,

Te6edf3dispatcherTb4b4b4: Te6edf3CoroutineDispatcherTb4b4b4,

Tb4b4b4) Tb4b4b4: Te6edf3UnifiedOtaProtocol Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3transportScope Tff7b72= Te6edf3CoroutineScopeTb4b4b4(Te6edf3SupervisorJobTb4b4b4(Tb4b4b4) Tff7b72+ Te6edf3dispatcherTb4b4b4)

Tff7b72private Tff7b72val Te6edf3bleConnection Tff7b72= Te6edf3connectionFactoryTb4b4b4.Te6edf3createTb4b4b4(Te6edf3transportScopeTb4b4b4, Ta5d6ff"Ta5d6ffBLE OTATa5d6ff"Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3otaChar Tff7b72= Te6edf3BleCharacteristicTb4b4b4(Te6edf3OTA_WRITE_CHARACTERISTICTb4b4b4)

Tff7b72private Tff7b72val Te6edf3txChar Tff7b72= Te6edf3BleCharacteristicTb4b4b4(Te6edf3OTA_NOTIFY_CHARACTERISTICTb4b4b4)

Tf0883e@Volatile Tff7b72private Tff7b72var Te6edf3otaServiceTb4b4b4: Te6edf3BleService? Tff7b72= Tff7b72null

Tf0883e@Volatile Tff7b72private Tff7b72var Te6edf3responseChannel Tff7b72= Te6edf3ChannelTff7b72<Tffa657StringTff7b72>Tb4b4b4(Te6edf3ChannelTb4b4b4.Te6edf3UNLIMITEDTb4b4b4)

T8b949e// Written from the connectionState collector (Dispatchers.Default) and read by the streaming loop's

T8b949e// connection-loss guard (Dispatchers.IO); @Volatile ensures the guard sees a mid-transfer disconnect.

Tf0883e@Volatile Tff7b72private Tff7b72var Te6edf3isConnected Tff7b72= Tff7b72false

Tf0883e@Volatile Tff7b72private Tff7b72var Te6edf3notificationJobTb4b4b4: Te6edf3Job? Tff7b72= Tff7b72null

Tf0883e@Volatile Tff7b72private Tff7b72var Te6edf3connectionStateJobTb4b4b4: Te6edf3Job? Tff7b72= Tff7b72null

T8b949e/** Scan for the device by MAC address (or MAC+1 for OTA mode) with retries. */

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffscanForOtaDeviceTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3BleDevice? Tb4b4b4{

Tff7b72val Te6edf3otaAddress Tff7b72= Te6edf3calculateMacPlusOneTb4b4b4(Te6edf3addressTb4b4b4)

Tff7b72val Te6edf3targetAddresses Tff7b72= Te6edf3setOfTb4b4b4(Te6edf3addressTb4b4b4, Te6edf3otaAddressTb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Will match target OTA device addressesTa5d6ff" Tb4b4b4}

Tff7b72return Te6edf3scanForBleDeviceTb4b4b4(Te6edf3scanner Tff7b72= Te6edf3scannerTb4b4b4, Te6edf3tag Tff7b72= Ta5d6ff"Ta5d6ffBLE OTATa5d6ff"Tb4b4b4, Te6edf3serviceUuid Tff7b72= Te6edf3OTA_SERVICE_UUIDTb4b4b4) Tb4b4b4{

Tffa657itTb4b4b4.Te6edf3address Tff7b72in Te6edf3targetAddresses

Tb4b4b4}

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffMagicNumberTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffLongMethodTa5d6ff"Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffconnectTb4b4b4(Tb4b4b4)Tb4b4b4: Te6edf3ResultTff7b72<Tffa657UnitTff7b72> Tff7b72= Te6edf3safeCatching Tb4b4b4{

Te6edf3otaService Tff7b72= Tff7b72null

Te6edf3notificationJobTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3notificationJob Tff7b72= Tff7b72null

Te6edf3connectionStateJobTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3connectionStateJob Tff7b72= Tff7b72null

Te6edf3isConnected Tff7b72= Tff7b72false

Te6edf3responseChannelTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3connectResponseChannel Tff7b72= Te6edf3ChannelTff7b72<Tffa657StringTff7b72>Tb4b4b4(Te6edf3ChannelTb4b4b4.Te6edf3UNLIMITEDTb4b4b4)

Te6edf3responseChannel Tff7b72= Te6edf3connectResponseChannel

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Waiting Tffd700$Te6edf3REBOOT_DELAYTa5d6ff for device to reboot into OTA mode...Ta5d6ff" Tb4b4b4}

Te6edf3delayTb4b4b4(Te6edf3REBOOT_DELAYTb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Connecting to OTA device using Kable...Ta5d6ff" Tb4b4b4}

Tff7b72val Te6edf3device Tff7b72=

Te6edf3scanForOtaDeviceTb4b4b4(Tb4b4b4)

Tff7b72?: Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3ConnectionFailedTb4b4b4(

Ta5d6ff"Ta5d6ffDevice not found. Ensure the device has rebooted into OTA mode and is advertising.Ta5d6ff"Tb4b4b4,

Tb4b4b4)

Te6edf3connectionStateJob Tff7b72=

Te6edf3bleConnectionTb4b4b4.Te6edf3connectionState

Tb4b4b4.Te6edf3onEach Tb4b4b4{ Te6edf3state Tff7b72-Tff7b72>

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Connection state changed to Tffd700$Te6edf3stateTa5d6ff" Tb4b4b4}

Te6edf3isConnected Tff7b72= Te6edf3state Tff7b72is Te6edf3BleConnectionStateTb4b4b4.Te6edf3Connected

Tb4b4b4}

Tb4b4b4.Te6edf3launchInTb4b4b4(Te6edf3transportScopeTb4b4b4)

Tff7b72try Tb4b4b4{

Tff7b72val Te6edf3finalState Tff7b72= Te6edf3bleConnectionTb4b4b4.Te6edf3connectAndAwaitTb4b4b4(Te6edf3deviceTb4b4b4, Te6edf3CONNECTION_TIMEOUTTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3finalState Tff7b72is Te6edf3BleConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Failed to connect to OTA device (state=Tffd700$Te6edf3finalStateTa5d6ff)Ta5d6ff" Tb4b4b4}

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3ConnectionFailedTb4b4b4(Ta5d6ff"Ta5d6ffFailed to connect to OTA deviceTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tb4b4b4} Tff7b72catch Tb4b4b4(Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffSwallowedExceptionTa5d6ff"Tb4b4b4) Te6edf3eTb4b4b4: Te6edf3kotlinxTb4b4b4.Te6edf3coroutinesTb4b4b4.Te6edf3TimeoutCancellationExceptionTb4b4b4) Tb4b4b4{

Te6edf3currentCoroutineContextTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3ensureActiveTb4b4b4(Tb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Timed out waiting to connect to OTA device. Error: Tffd700${Te6edf3eTb4b4b4.Te6edf3messageTffd700}Ta5d6ff" Tb4b4b4}

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TimeoutTb4b4b4(Ta5d6ff"Ta5d6ffTimed out connecting to OTA deviceTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72val Te6edf3cacheInvalidated Tff7b72= Te6edf3bleConnectionTb4b4b4.Te6edf3invalidateServiceCacheTb4b4b4(Tb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: GATT cache invalidation requested: Tffd700$Te6edf3cacheInvalidatedTa5d6ff" Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3cacheInvalidatedTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Invalidated stale GATT service cache before OTA discoveryTa5d6ff" Tb4b4b4}

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: GATT cache invalidation not available; proceeding with existing service cacheTa5d6ff" Tb4b4b4}

Tb4b4b4}

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Connected to OTA device, discovering services...Ta5d6ff" Tb4b4b4}

Tff7b72try Tb4b4b4{

Te6edf3discoverAndPrepareOtaServiceTb4b4b4(Te6edf3deviceTb4b4b4, Te6edf3connectResponseChannelTb4b4b4, Te6edf3cacheInvalidatedTb4b4b4)

Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4: Te6edf3TimeoutCancellationExceptionTb4b4b4) Tb4b4b4{

Te6edf3otaService Tff7b72= Tff7b72null

Te6edf3currentCoroutineContextTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3ensureActiveTb4b4b4(Tb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Timed out waiting for OTA service discovery. Error: Tffd700${Te6edf3eTb4b4b4.Te6edf3messageTffd700}Ta5d6ff" Tb4b4b4}

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TimeoutTb4b4b4(Ta5d6ff"Ta5d6ffTimed out waiting for BLE OTA service discoveryTa5d6ff"Tb4b4b4)

Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4: Te6edf3OtaProtocolExceptionTb4b4b4) Tb4b4b4{

Te6edf3otaService Tff7b72= Tff7b72null

Tff7b72throw Te6edf3e

Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4: Te6edf3kotlinxTb4b4b4.Te6edf3coroutinesTb4b4b4.Te6edf3CancellationExceptionTb4b4b4) Tb4b4b4{

Te6edf3otaService Tff7b72= Tff7b72null

Tff7b72throw Te6edf3e

Tb4b4b4} Tff7b72catch Tb4b4b4(Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooGenericExceptionCaughtTa5d6ff"Tb4b4b4) Te6edf3eTb4b4b4: Te6edf3ExceptionTb4b4b4) Tb4b4b4{

Te6edf3otaService Tff7b72= Tff7b72null

Te6edf3LoggerTb4b4b4.Te6edf3wTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Failed to prepare OTA serviceTa5d6ff" Tb4b4b4}

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3ConnectionFailedTb4b4b4(Ta5d6ff"Ta5d6ffFailed to prepare BLE OTA serviceTa5d6ff"Tb4b4b4, Te6edf3eTb4b4b4)

Tb4b4b4}

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffLongMethodTa5d6ff"Tb4b4b4)

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffdiscoverAndPrepareOtaServiceTb4b4b4(

Te6edf3deviceTb4b4b4: Te6edf3BleDeviceTb4b4b4,

Te6edf3connectResponseChannelTb4b4b4: Te6edf3ChannelTff7b72<Tffa657StringTff7b72>Tb4b4b4,

Te6edf3cacheInvalidatedTb4b4b4: Tffa657BooleanTb4b4b4,

Tb4b4b4) Tb4b4b4{

Tff7b72suspend Tff7b72fun Td2a8ffprepareProfileTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3bleConnectionTb4b4b4.Te6edf3profileTb4b4b4(Te6edf3OTA_SERVICE_UUIDTb4b4b4) Tb4b4b4{ Te6edf3service Tff7b72-Tff7b72>

Te6edf3serviceTb4b4b4.Te6edf3requireOtaCharacteristicsTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3maxLen Tff7b72= Te6edf3bleConnectionTb4b4b4.Te6edf3maximumWriteValueLengthTb4b4b4(Te6edf3BleWriteTypeTb4b4b4.Te6edf3WITHOUT_RESPONSETb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Service ready. Max write value length: Tffd700$Te6edf3maxLenTa5d6ff bytesTa5d6ff" Tb4b4b4}

Tff7b72val Te6edf3notificationsReady Tff7b72= Te6edf3CompletableDeferredTff7b72<Tffa657UnitTff7b72>Tb4b4b4(Tb4b4b4)

Te6edf3notificationJob Tff7b72=

Te6edf3launchTb4b4b4(Te6edf3start Tff7b72= Te6edf3CoroutineStartTb4b4b4.Te6edf3UNDISPATCHEDTb4b4b4) Tb4b4b4{

Te6edf3service

Tb4b4b4.Te6edf3observeTb4b4b4(Te6edf3txCharTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: TX characteristic subscribedTa5d6ff" Tb4b4b4}

Te6edf3notificationsReadyTb4b4b4.Te6edf3completeTb4b4b4(Tffa657UnitTb4b4b4)

Tb4b4b4}

Tb4b4b4.Te6edf3onEach Tb4b4b4{ Te6edf3notifyBytes Tff7b72-Tff7b72>

Tff7b72try Tb4b4b4{

Tff7b72val Te6edf3response Tff7b72= Te6edf3notifyBytesTb4b4b4.Te6edf3decodeToStringTb4b4b4(Tb4b4b4)

Te6edf3LoggerTb4b4b4.Te6edf3d Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Received response: Tffd700$Te6edf3responseTa5d6ff" Tb4b4b4}

Te6edf3connectResponseChannelTb4b4b4.Te6edf3trySendTb4b4b4(Te6edf3responseTb4b4b4)

Tb4b4b4} Tff7b72catch Tb4b4b4(Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooGenericExceptionCaughtTa5d6ff"Tb4b4b4) Te6edf3eTb4b4b4: Te6edf3ExceptionTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Failed to decode response bytesTa5d6ff" Tb4b4b4}

Tb4b4b4}

Tb4b4b4.Te6edf3catch Tb4b4b4{ Te6edf3e Tff7b72-Tff7b72>

Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3eTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Error in TX characteristic notification flowTa5d6ff" Tb4b4b4}

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3notificationsReadyTb4b4b4.Te6edf3isCompletedTb4b4b4) Tb4b4b4{

Te6edf3notificationsReadyTb4b4b4.Te6edf3completeExceptionallyTb4b4b4(Te6edf3eTb4b4b4)

Tb4b4b4}

Te6edf3connectResponseChannelTb4b4b4.Te6edf3closeTb4b4b4(Te6edf3eTb4b4b4)

Tb4b4b4}

Tb4b4b4.Te6edf3collectTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72val Te6edf3confirmed Tff7b72= Te6edf3withTimeoutOrNullTb4b4b4(Te6edf3SUBSCRIPTION_SETTLETb4b4b4) Tb4b4b4{ Te6edf3notificationsReadyTb4b4b4.Te6edf3awaitTb4b4b4(Tb4b4b4) Tb4b4b4} Tff7b72!Tff7b72= Tff7b72null

Tff7b72if Tb4b4b4(Te6edf3confirmedTb4b4b4) Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: TX notifications subscribedTa5d6ff" Tb4b4b4}

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{

Ta5d6ff"Ta5d6ffBLE OTA: TX notification subscription not confirmed after Tffd700$Te6edf3SUBSCRIPTION_SETTLETa5d6ff; Ta5d6ff" Tff7b72+

Ta5d6ff"Ta5d6ffcontinuing with bounded settle fallbackTa5d6ff"

Tb4b4b4}

Te6edf3otaService Tff7b72= Te6edf3service

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Service discovered and readyTa5d6ff" Tb4b4b4}

Tb4b4b4}

Tff7b72try Tb4b4b4{

Te6edf3prepareProfileTb4b4b4(Tb4b4b4)

Tb4b4b4} Tff7b72catch Tb4b4b4(Te6edf3eTb4b4b4: Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3ConnectionFailedTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3cacheInvalidatedTb4b4b4) Tff7b72throw Te6edf3e

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{

Ta5d6ff"Ta5d6ffBLE OTA: OTA characteristics missing after cache refresh; reconnecting to force service rediscoveryTa5d6ff"

Tb4b4b4}

Te6edf3notificationJobTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3notificationJob Tff7b72= Tff7b72null

Te6edf3otaService Tff7b72= Tff7b72null

Te6edf3bleConnectionTb4b4b4.Te6edf3disconnectTb4b4b4(Tb4b4b4)

Te6edf3delayTb4b4b4(Te6edf3CACHE_REFRESH_RECONNECT_DELAYTb4b4b4)

Tff7b72val Te6edf3reconnectState Tff7b72= Te6edf3bleConnectionTb4b4b4.Te6edf3connectAndAwaitTb4b4b4(Te6edf3deviceTb4b4b4, Te6edf3CONNECTION_TIMEOUTTb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3reconnectState Tff7b72is Te6edf3BleConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4) Tb4b4b4{

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3ConnectionFailedTb4b4b4(Ta5d6ff"Ta5d6ffFailed to reconnect to OTA device after cache refreshTa5d6ff"Tb4b4b4)

Tb4b4b4}

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Reconnected after cache refresh for OTA service rediscoveryTa5d6ff" Tb4b4b4}

Te6edf3prepareProfileTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffstartOtaTb4b4b4(

Te6edf3sizeBytesTb4b4b4: Tffa657LongTb4b4b4,

Te6edf3sha256HashTb4b4b4: Tffa657StringTb4b4b4,

Te6edf3onHandshakeStatusTb4b4b4: Te6edf3suspend Tb4b4b4(Te6edf3OtaHandshakeStatusTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,

Tb4b4b4)Tb4b4b4: Te6edf3ResultTff7b72<Tffa657UnitTff7b72> Tff7b72= Te6edf3safeCatching Tb4b4b4{

Tff7b72val Te6edf3command Tff7b72= Te6edf3OtaCommandTb4b4b4.Te6edf3StartOtaTb4b4b4(Te6edf3sizeBytesTb4b4b4, Te6edf3sha256HashTb4b4b4)

Te6edf3sendCommandTb4b4b4(Te6edf3commandTb4b4b4)

T8b949e// Drive on response *type*, never a fragment/response count: the handshake completes only on an explicit OK.

T8b949e// ERASING is an interim progress notification the device may emit before OK, so it just continues the wait. At

T8b949e// a low MTU the command splits into multiple writes; gating completion on a write count would desync against

T8b949e// the device's single OK — the same fragment-count bug PR #5915 removed from streamFirmware.

Tff7b72var Te6edf3handshakeComplete Tff7b72= Tff7b72false

Tff7b72while Tb4b4b4(Tff7b72!Te6edf3handshakeCompleteTb4b4b4) Tb4b4b4{

Tff7b72when Tb4b4b4(Tff7b72val Te6edf3parsed Tff7b72= Te6edf3OtaResponseTb4b4b4.Te6edf3parseTb4b4b4(Te6edf3waitForResponseTb4b4b4(Te6edf3ERASING_TIMEOUTTb4b4b4)Tb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72is Te6edf3OtaResponseTb4b4b4.Te6edf3Ok Tff7b72-Tff7b72> Te6edf3handshakeComplete Tff7b72= Tff7b72true

Tff7b72is Te6edf3OtaResponseTb4b4b4.Te6edf3Erasing Tff7b72-Tff7b72> Tb4b4b4{

Te6edf3LoggerTb4b4b4.Te6edf3i Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Device erasing flash...Ta5d6ff" Tb4b4b4}

Te6edf3onHandshakeStatusTb4b4b4(Te6edf3OtaHandshakeStatusTb4b4b4.Te6edf3ErasingTb4b4b4)

Tb4b4b4}

Tff7b72is Te6edf3OtaResponseTb4b4b4.Te6edf3Error Tff7b72-Tff7b72> Tb4b4b4{

Tff7b72if Tb4b4b4(Te6edf3parsedTb4b4b4.Te6edf3messageTb4b4b4.Te6edf3containsTb4b4b4(Ta5d6ff"Ta5d6ffHash RejectedTa5d6ff"Tb4b4b4, Te6edf3ignoreCase Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3HashRejectedTb4b4b4(Te6edf3sha256HashTb4b4b4)

Tb4b4b4}

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3CommandFailedTb4b4b4(Te6edf3commandTb4b4b4, Te6edf3parsedTb4b4b4)

Tb4b4b4}

Tff7b72else Tff7b72-Tff7b72> Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{ Ta5d6ff"Ta5d6ffBLE OTA: Unexpected handshake response: Tffd700$Te6edf3parsedTa5d6ff" Tb4b4b4}

Tb4b4b4}

T8b949e/**

* Streams firmware to the device. The ESP32 OTA loader is an ACK-paced byte stream: it drains its receive buffer

* and emits exactly ONE response per drain — an `ACK` while more data is expected, or the terminal `OK` once the

* final byte is received and the image verified. To keep a deterministic 1-write → 1-response cadence at any MTU,

* each chunk is sent as a single GATT write no larger than the negotiated write payload. A chunk that exceeded the

* payload would fragment into multiple writes that the device coalesces into one response, desyncing our response

* accounting (the cause of the prior ACK-timeout hang at MTU 512, where a 512-byte chunk split into [509, 3]).

*

* Because we write one chunk then await its single response before writing the next, only one chunk is ever

* outstanding, so the device's byte-stream receive buffer holds exactly one chunk per drain — keeping the cadence a

* deterministic 1 write → 1 response. Branch on response *type* (never on a fragment count): success requires an

* explicit terminal `OK`, and any `ERR` fails the transfer, so a late device error can never be reported as

* success.

*/

Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffMagicNumberTa5d6ff"Tb4b4b4)

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffstreamFirmwareTb4b4b4(

Te6edf3dataTb4b4b4: Te6edf3ByteArrayTb4b4b4,

Te6edf3chunkSizeTb4b4b4: Tffa657IntTb4b4b4,

Te6edf3onProgressTb4b4b4: Te6edf3suspend Tb4b4b4(Tffa657FloatTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,

Tb4b4b4)Tb4b4b4: Te6edf3ResultTff7b72<Tffa657UnitTff7b72> Tff7b72= Te6edf3safeCatching Tb4b4b4{

Tff7b72val Te6edf3totalBytes Tff7b72= Te6edf3dataTb4b4b4.Te6edf3size

Tff7b72if Tb4b4b4(Te6edf3totalBytes Tff7b72=Tff7b72= T79c0ff0Tb4b4b4) Tb4b4b4{

T8b949e// Fail now: an empty image would otherwise skip the loop and then wait out the full

T8b949e// VERIFICATION_TIMEOUT before failing.

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TransferFailedTb4b4b4(Ta5d6ff"Ta5d6ffFirmware is emptyTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72var Te6edf3sentBytes Tff7b72= T79c0ff0

Tff7b72val Te6edf3writePayload Tff7b72= Te6edf3bleConnectionTb4b4b4.Te6edf3maximumWriteValueLengthTb4b4b4(Te6edf3BleWriteTypeTb4b4b4.Te6edf3WITHOUT_RESPONSETb4b4b4) Tff7b72?: Te6edf3SAFE_WRITE_PAYLOAD

Tff7b72val Te6edf3effectiveChunkSize Tff7b72= Te6edf3minOfTb4b4b4(Te6edf3chunkSizeTb4b4b4, Te6edf3writePayloadTb4b4b4)Tb4b4b4.Te6edf3coerceAtLeastTb4b4b4(T79c0ff1Tb4b4b4)

Tff7b72while Tb4b4b4(Te6edf3sentBytes Tff7b72< Te6edf3totalBytesTb4b4b4) Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3isConnectedTb4b4b4) Tb4b4b4{

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TransferFailedTb4b4b4(Ta5d6ff"Ta5d6ffConnection lost during transferTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72val Te6edf3currentChunkSize Tff7b72= Te6edf3minOfTb4b4b4(Te6edf3effectiveChunkSizeTb4b4b4, Te6edf3totalBytes Tff7b72- Te6edf3sentBytesTb4b4b4)

Tff7b72val Te6edf3chunk Tff7b72= Te6edf3dataTb4b4b4.Te6edf3copyOfRangeTb4b4b4(Te6edf3sentBytesTb4b4b4, Te6edf3sentBytes Tff7b72+ Te6edf3currentChunkSizeTb4b4b4)

Tff7b72val Te6edf3isLastChunk Tff7b72= Te6edf3sentBytes Tff7b72+ Te6edf3currentChunkSize Tff7b72>Tff7b72= Te6edf3totalBytes

Tff7b72val Te6edf3packetsSent Tff7b72= Te6edf3writeDataTb4b4b4(Te6edf3chunkTb4b4b4, Te6edf3BleWriteTypeTb4b4b4.Te6edf3WITHOUT_RESPONSETb4b4b4)

Tff7b72if Tb4b4b4(Te6edf3packetsSent Tff7b72!Tff7b72= T79c0ff1Tb4b4b4) Tb4b4b4{

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TransferFailedTb4b4b4(Ta5d6ff"Ta5d6ffChunk produced Tffd700$Te6edf3packetsSentTa5d6ff writes, expected exactly oneTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72when Tb4b4b4(Tff7b72val Te6edf3parsed Tff7b72= Te6edf3OtaResponseTb4b4b4.Te6edf3parseTb4b4b4(Te6edf3waitForResponseTb4b4b4(Te6edf3ACK_TIMEOUTTb4b4b4)Tb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72is Te6edf3OtaResponseTb4b4b4.Te6edf3Ack Tff7b72-Tff7b72> Tffa657Unit

Tff7b72is Te6edf3OtaResponseTb4b4b4.Te6edf3Ok Tff7b72-Tff7b72>

Tff7b72if Tb4b4b4(Te6edf3isLastChunkTb4b4b4) Tb4b4b4{

Te6edf3sentBytes Tff7b72+Tff7b72= Te6edf3currentChunkSize

Te6edf3onProgressTb4b4b4(T79c0ff1.0fTb4b4b4)

Tff7b72returnTf0883e@safeCatching Tffa657Unit

Tb4b4b4} Tff7b72else Tb4b4b4{

T8b949e// The device sends OK only once the full image is received; an OK before the final chunk

T8b949e// means its size accounting disagrees with ours — fail closed rather than treat it as an ACK.

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TransferFailedTb4b4b4(Ta5d6ff"Ta5d6ffReceived OK before the final chunkTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72is Te6edf3OtaResponseTb4b4b4.Te6edf3Error Tff7b72-Tff7b72> Tff7b72throw Te6edf3transferExceptionTb4b4b4(Te6edf3parsedTb4b4b4)

Tff7b72else Tff7b72-Tff7b72> Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TransferFailedTb4b4b4(Ta5d6ff"Ta5d6ffUnexpected response during transfer: Tffd700$Te6edf3parsedTa5d6ff"Tb4b4b4)

Tb4b4b4}

Te6edf3sentBytes Tff7b72+Tff7b72= Te6edf3currentChunkSize

Te6edf3onProgressTb4b4b4(Te6edf3sentBytesTb4b4b4.Te6edf3toFloatTb4b4b4(Tb4b4b4) Tff7b72/ Te6edf3totalBytesTb4b4b4)

Tb4b4b4}

T8b949e// Every chunk was acknowledged with ACK but the terminal OK has not arrived (e.g. the device expected more

T8b949e// bytes than we sent) — wait for the device's final verification result rather than reporting success.

Tff7b72when Tb4b4b4(Tff7b72val Te6edf3parsed Tff7b72= Te6edf3OtaResponseTb4b4b4.Te6edf3parseTb4b4b4(Te6edf3waitForResponseTb4b4b4(Te6edf3VERIFICATION_TIMEOUTTb4b4b4)Tb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72is Te6edf3OtaResponseTb4b4b4.Te6edf3Ok Tff7b72-Tff7b72> Tffa657Unit

Tff7b72is Te6edf3OtaResponseTb4b4b4.Te6edf3Error Tff7b72-Tff7b72> Tff7b72throw Te6edf3transferExceptionTb4b4b4(Te6edf3parsedTb4b4b4)

Tff7b72else Tff7b72-Tff7b72> Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TransferFailedTb4b4b4(Ta5d6ff"Ta5d6ffExpected OK after transfer, got: Tffd700$Te6edf3parsedTa5d6ff"Tb4b4b4)

Tb4b4b4}

T8b949e/**

* Maps a device `ERR` response to the appropriate transfer exception (hash mismatch is verification, else generic).

*/

Tff7b72private Tff7b72fun Td2a8fftransferExceptionTb4b4b4(Te6edf3errorTb4b4b4: Te6edf3OtaResponseTb4b4b4.Te6edf3ErrorTb4b4b4)Tb4b4b4: Te6edf3OtaProtocolException Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3errorTb4b4b4.Te6edf3messageTb4b4b4.Te6edf3containsTb4b4b4(Ta5d6ff"Ta5d6ffHash MismatchTa5d6ff"Tb4b4b4, Te6edf3ignoreCase Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3VerificationFailedTb4b4b4(Ta5d6ff"Ta5d6ffFirmware hash mismatch after transferTa5d6ff"Tb4b4b4)

Tb4b4b4} Tff7b72else Tb4b4b4{

Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TransferFailedTb4b4b4(Ta5d6ff"Ta5d6ffTransfer failed: Tffd700${Te6edf3errorTb4b4b4.Te6edf3messageTffd700}Ta5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72override Tff7b72suspend Tff7b72fun Td2a8ffcloseTb4b4b4(Tb4b4b4) Tb4b4b4{

Te6edf3notificationJobTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3notificationJob Tff7b72= Tff7b72null

Te6edf3connectionStateJobTff7b72?.Te6edf3cancelTb4b4b4(Tb4b4b4)

Te6edf3connectionStateJob Tff7b72= Tff7b72null

Te6edf3otaService Tff7b72= Tff7b72null

Te6edf3responseChannelTb4b4b4.Te6edf3closeTb4b4b4(Tb4b4b4)

Te6edf3bleConnectionTb4b4b4.Te6edf3disconnectTb4b4b4(Tb4b4b4)

Te6edf3isConnected Tff7b72= Tff7b72false

Te6edf3transportScopeTb4b4b4.Te6edf3cancelTb4b4b4(Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffsendCommandTb4b4b4(Te6edf3commandTb4b4b4: Te6edf3OtaCommandTb4b4b4)Tb4b4b4: Tffa657Int Tb4b4b4{

Tff7b72val Te6edf3data Tff7b72= Te6edf3commandTb4b4b4.Te6edf3toStringTb4b4b4(Tb4b4b4)Tb4b4b4.Te6edf3encodeToByteArrayTb4b4b4(Tb4b4b4)

Tff7b72return Te6edf3writeDataTb4b4b4(Te6edf3dataTb4b4b4, Te6edf3BleWriteTypeTb4b4b4.Te6edf3WITH_RESPONSETb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffwriteDataTb4b4b4(Te6edf3dataTb4b4b4: Te6edf3ByteArrayTb4b4b4, Te6edf3writeTypeTb4b4b4: Te6edf3BleWriteTypeTb4b4b4)Tb4b4b4: Tffa657Int Tb4b4b4{

Tff7b72val Te6edf3service Tff7b72= Te6edf3otaService Tff7b72?: Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TransferFailedTb4b4b4(Ta5d6ff"Ta5d6ffBLE OTA service is not readyTa5d6ff"Tb4b4b4)

T8b949e// takeIf { it > 0 }: a non-positive negotiated length would stall the loop (offset never advances); fall

T8b949e// back to a single whole-buffer write instead of looping forever.

Tff7b72val Te6edf3maxLen Tff7b72= Te6edf3bleConnectionTb4b4b4.Te6edf3maximumWriteValueLengthTb4b4b4(Te6edf3writeTypeTb4b4b4)Tff7b72?.Te6edf3takeIf Tb4b4b4{ Tffa657it Tff7b72> T79c0ff0 Tb4b4b4} Tff7b72?: Te6edf3dataTb4b4b4.Te6edf3size

Tff7b72var Te6edf3offset Tff7b72= T79c0ff0

Tff7b72var Te6edf3packetsSent Tff7b72= T79c0ff0

Tff7b72try Tb4b4b4{

Tff7b72while Tb4b4b4(Te6edf3offset Tff7b72< Te6edf3dataTb4b4b4.Te6edf3sizeTb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3chunkSize Tff7b72= Te6edf3minOfTb4b4b4(Te6edf3dataTb4b4b4.Te6edf3size Tff7b72- Te6edf3offsetTb4b4b4, Te6edf3maxLenTb4b4b4)

Tff7b72val Te6edf3packet Tff7b72= Te6edf3dataTb4b4b4.Te6edf3copyOfRangeTb4b4b4(Te6edf3offsetTb4b4b4, Te6edf3offset Tff7b72+ Te6edf3chunkSizeTb4b4b4)

Te6edf3serviceTb4b4b4.Te6edf3writeTb4b4b4(Te6edf3otaCharTb4b4b4, Te6edf3packetTb4b4b4, Te6edf3writeTypeTb4b4b4)

Te6edf3offset Tff7b72+Tff7b72= Te6edf3chunkSize

Te6edf3packetsSentTff7b72+Tff7b72+

Tb4b4b4}

Tb4b4b4} Tff7b72catch Tb4b4b4(Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooGenericExceptionCaughtTa5d6ff"Tb4b4b4) Te6edf3eTb4b4b4: Te6edf3ExceptionTb4b4b4) Tb4b4b4{

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TransferFailedTb4b4b4(Ta5d6ff"Ta5d6ffFailed to write data at offset Tffd700$Te6edf3offsetTa5d6ff"Tb4b4b4, Te6edf3eTb4b4b4)

Tb4b4b4}

Tff7b72return Te6edf3packetsSent

Tb4b4b4}

Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffwaitForResponseTb4b4b4(Te6edf3timeoutTb4b4b4: Te6edf3DurationTb4b4b4)Tb4b4b4: Tffa657String Tff7b72= Te6edf3responseChannelTb4b4b4.Te6edf3receiveWithinTb4b4b4(Te6edf3timeoutTb4b4b4) Tb4b4b4{

Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3TimeoutTb4b4b4(Ta5d6ff"Ta5d6ffTimeout waiting for response after Tffd700$Te6edf3timeoutTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Te6edf3BleServiceTb4b4b4.Td2a8ffrequireOtaCharacteristicsTb4b4b4(Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3missing Tff7b72= Te6edf3mutableListOfTff7b72<Tffa657StringTff7b72>Tb4b4b4(Tb4b4b4)

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3hasCharacteristicTb4b4b4(Te6edf3txCharTb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3missingTb4b4b4.Te6edf3addTb4b4b4(Ta5d6ff"Ta5d6ffTX notify characteristic Tffd700$Te6edf3txCharTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3hasCharacteristicTb4b4b4(Te6edf3otaCharTb4b4b4)Tb4b4b4) Tb4b4b4{

Te6edf3missingTb4b4b4.Te6edf3addTb4b4b4(Ta5d6ff"Ta5d6ffOTA write characteristic Tffd700$Te6edf3otaCharTa5d6ff"Tb4b4b4)

Tb4b4b4}

Tff7b72if Tb4b4b4(Te6edf3missingTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{

Tff7b72val Te6edf3discovered Tff7b72= Te6edf3discoveredCharacteristicUuidsTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3diagnostic Tff7b72=

Tff7b72if Tb4b4b4(Te6edf3discoveredTb4b4b4.Te6edf3isNotEmptyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{

Ta5d6ff"Ta5d6ff (discovered characteristics: Tffd700$Te6edf3discoveredTa5d6ff)Ta5d6ff"

Tb4b4b4} Tff7b72else Tb4b4b4{

Ta5d6ff"Ta5d6ff (no characteristics discovered for OTA service)Ta5d6ff"

Tb4b4b4}

Tff7b72throw Te6edf3OtaProtocolExceptionTb4b4b4.Te6edf3ConnectionFailedTb4b4b4(

Ta5d6ff"Ta5d6ffESP32 OTA service was missing required characteristics after BLE service discovery: Ta5d6ff" Tff7b72+

Te6edf3missingTb4b4b4.Te6edf3joinToStringTb4b4b4(Te6edf3separator Tff7b72= Ta5d6ff"Ta5d6ff; Ta5d6ff"Tb4b4b4) Tff7b72+

Te6edf3diagnosticTb4b4b4,

Tb4b4b4)

Tb4b4b4}

Tff7b72companion Tff7b72object Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3CONNECTION_TIMEOUT Tff7b72= T79c0ff1T79c0ff5.Te6edf3seconds

Tff7b72private Tff7b72val Te6edf3SUBSCRIPTION_SETTLE Tff7b72= T79c0ff5T79c0ff0T79c0ff0.Te6edf3milliseconds

Tff7b72private Tff7b72val Te6edf3ERASING_TIMEOUT Tff7b72= T79c0ff6T79c0ff0.Te6edf3seconds

Tff7b72private Tff7b72val Te6edf3ACK_TIMEOUT Tff7b72= T79c0ff1T79c0ff0.Te6edf3seconds

Tff7b72private Tff7b72val Te6edf3VERIFICATION_TIMEOUT Tff7b72= T79c0ff1T79c0ff0.Te6edf3seconds

Tff7b72private Tff7b72val Te6edf3REBOOT_DELAY Tff7b72= T79c0ff5.Te6edf3seconds

Tff7b72private Tff7b72val Te6edf3CACHE_REFRESH_RECONNECT_DELAY Tff7b72= T79c0ff1.Te6edf3seconds

Tff7b72const Tff7b72val Te6edf3RECOMMENDED_CHUNK_SIZE Tff7b72= T79c0ff5T79c0ff1T79c0ff2

T8b949e/** Fallback write payload when the MTU has not been negotiated (23-byte ATT MTU minus the 3-byte header). */

Tff7b72private Tff7b72const Tff7b72val Te6edf3SAFE_WRITE_PAYLOAD Tff7b72= T79c0ff2T79c0ff0

Tb4b4b4}